package com.gnerv.pabu.basic.core.service;

public interface IKafkaListenerService {

    boolean startListener(String listenerId);

    boolean stopListener(String listenerId);
}
